package com.link.serve.kafka.proto;

import lombok.Data;
import lombok.experimental.Accessors;

@Data
@Accessors(chain = true)
public class KafkaMessage {
    private String operationType; // Redis操作类型
    private Long userId;          // 用户ID
    private Long serverId;        // 服务器ID
    private String key;           // key
    private String message;       // 消息内容
}
